package com.yupi.springbootinit.service;

import com.influxdb.client.QueryApi;
import com.influxdb.client.InfluxDBClient;
import com.influxdb.query.FluxTable;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * InfluxDB 2.x 通用查询服务（Flux）
 * 说明：优先直接使用 InfluxRepository 的封装；如需执行临时 Flux，可使用本服务。
 */
@Service
@RequiredArgsConstructor
public class InfluxQueryService {

    private final InfluxDBClient influxDBClient;

    public List<FluxTable> queryFlux(String flux) {
        QueryApi queryApi = influxDBClient.getQueryApi();
        return queryApi.query(flux);
    }
}